package io.xxx.mario.task.receive;

import io.xxx.mario.task.Task;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Flux;

/**
 * 通过读取外部数据源获得接收者信息，例如通过门店标签从门店服务中读取命中所选标签的门店，或者通过标签从画像文件中读取
 */
@Slf4j
@Component
public class ExternalReceiverSelector implements ReceiverSelector {

    @Override
    public Flux<Receiver> select(Task task) {
        return Flux.empty();
    }
}
